//api路由
//userApi.js —— 测试用 API 示例

var models = require('../db');
var express = require('express');
var router = express.Router();
var mysql = require('mysql');
var $sql = require('../sqlMap');
// 连接数据库
var conn = mysql.createConnection(models.mysql);
conn.connect();
// var jsonWrite = function (res, ret) {
//     if (typeof ret === 'undefined') {
//         res.json({
//             code: '1', msg: '操作失败'
//         });
//     }
//     else {
//         res.json(
//             ret
//         );
//     }
// };
// 增加用户接口

router.post('/addUser', (req, res) => {
    var sql = $sql.userdata.add;
    var init_sql = $sql.userdata.init;
    var params = req.body;

    conn.query(init_sql, function (err, result) {
        if (err) {
            console.log(err);
        }
        if (result) {
            // jsonWrite(res, result);
        }
    });
    params.forEach(obj => {
        const values = [
          obj.field1,
          obj.field2,
          obj.field3,
          obj.field4,
          obj.field5,
          obj.field6,
          obj.field7,
          obj.field8
        ];

    conn.query(sql, values, function (err, result) {
        if (err) {
            console.log(err);
        }
        if (result) {
            // jsonWrite(res, result);
        }
    });
});
    // 在所有查询完成后发送一次响应
    res.json({ message: '用户数据添加成功' });
})

router.get('/query',(req,res)=>{
    conn.query('select * from userdata',function(err,row){
        if(err){
             console.log(err)            
        }
        let data = JSON.stringify(row)
        res.end(data)
    })
});

module.exports = router;

